package org.batch.service.batch;

/**
 * 批处理相关操作接口
 *
 * @author LiKun
 * @date 2021/9/27 10:21
 */
public interface BatchService {
    /**
     * 批量处理交易数据
     *
     * @param account 账户ID
     *
     * @throws Exception 相关异常
     */
    void batchDealTrading(String account) throws Exception;

    /**
     * 批量数据持久化到数据库
     *
     * @param path   文件路径
     * @param fields 类型字段
     *
     * @throws Exception 批处理执行异常
     */
    void batchTradingPersistence(String path, String fields) throws Exception;
}
